//package com.example.kafkademo.producer;
//
//import io.vertx.core.Future;
//import io.vertx.core.Vertx;
//import io.vertx.core.json.JsonObject;
//import io.vertx.kafka.client.producer.KafkaProducer;
//import io.vertx.kafka.client.producer.KafkaProducerRecord;
//import io.vertx.kafka.client.serialization.JsonObjectSerializer;
//import org.apache.kafka.common.serialization.StringSerializer;
//
//import java.util.Properties;
//
//public final class VertxProducer {
//
//    public static void main(String[] args) {
//
//        Vertx vertx=Vertx.vertx();
//        final Properties props = new Properties();
//        props.put("bootstrap.servers", "192.168.1.14:9092");  //kafka主机地址
//        props.put("acks", "all");  //最慢最持久的提交消息
//
//        //这里和生产者的<key,value>必须要一一对应
//        props.put("key.serializer", StringSerializer.class.getName());
//        props.put("value.serializer", JsonObjectSerializer.class.getName());
//
//        KafkaProducer<String, JsonObject> producer=KafkaProducer.createShared(vertx, "hexingjie", props);
//
//        final Future<JsonObject> future = Future.future();
//        //这里在控制台存在中文乱码问题，但是不影响。代码中是正常显示
//        producer.write(KafkaProducerRecord.create("huahua", "自由",new JsonObject().put("加油","漂亮") ), ar -> {
//            if (ar.succeeded()) {
//                System.out.println("vertx+kafka组合成功！！！");
//                future.complete();
//            } else {
//                System.out.println("vertx+kafka组合失败！！！");
//                future.fail(ar.cause());
//            }
//        });
//    }
//
//}
